package net.pws.common.simplemq;


public interface DataPipe {
    
    /**
     * append to a queue
     * 
     * @param data
     */
    public void addData(Object data);
    
    /**
     * append to a scheduled queue
     * 
     * @param data
     */
    public void addLazyData(Object data);
    
    /**
     * append to a scheduled queue by specified delay time unit
     * 
     * @param data
     * @param delay
     *            TimeUnit.SECONDS
     */
    public void addLazyData(Object data, int delay);
}
